package com.yuaer.demo.springsparkjobhandlerdemo.executor;

import lombok.AllArgsConstructor;
import lombok.Data;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

import java.util.Map;

/**
 * 节点上下文
 */
@Data
@AllArgsConstructor
public class NodeContext {
    private final String nodeId;
    private final Map<String, Dataset<Row>> inputs;  // 仅当前节点依赖的输入
    private final Map<String, Object> params;        // 当前节点参数

    // 可选：日志、重试次数、调试标志、监控指标等
}